package com.shujia.test

import org.apache.flink.streaming.api.scala._

object TestFlink {

  def main(args: Array[String]): Unit = {

    val env = StreamExecutionEnvironment.getExecutionEnvironment

    val sourceDS = env.socketTextStream("node1", 9999)

    sourceDS.print()

    env.execute("test")

  }

}
